package com.实战;

import reactor.core.publisher.Flux;

/**这是一个新闻订阅的示例，思考如何利用新的响应式接口使其变得更智能。
 * @author zhangsulei
 *
 */
public class NewsServiceDemo {

	public static void main(String[] args) {
		Flux<String> newsService = Flux.<String>just("新闻1", "新闻2");
		// 通过在newService实例上调用subscribe方法，我们表达了获取最新新闻的期望。通常在发送任何新闻摘要之前，高质量服务都会先发送祝贺信，
		// 而祝贺信将包含有关订阅和取消订阅的信息。此操作与我们的Subscriber#onSubscribe方法完全相同，该方法通知Subscriber已成功订阅
		// 并使其能够取消订阅
		NewsServiceSubscriber subscriber = new NewsServiceSubscriber(5);
		newsService.subscribe(subscriber);

		subscriber.eventuallyReadDigest();
	}

}
